/**   
* @Title:：RabbitClusterChannel.java 
* @Package ：com.example.deal.rabbit 
* @Description： RabbitMQ Channel Design
* @author： Dustyone
* @date： 2019年4月4日 上午9:49:21  
*/
package com.example.deal.rabbit;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

/**
 * @ClassName:：RabbitClusterChannel
 * @author ：Dustyone
 * @date ：2019年4月4日 上午9:49:21
 */
public interface RabbitClusterChannel {
	
	/**
	 * Message consumed call back to confirm channel;
	 */
	public String MESSAGE_CONFIRM_CHANNEL = "message_confirm_channel";
	
	/**
	 * Asia CDS Broker waring notify channel
	 */
	public String ASIA_CDS_BROKER_NOTIFY_WARNING = "asia_cds_broker_notify_warning";

	/**
	 * euro CDS Broker waring notify channel
	 */
	public String EURO_CDS_BROKER_NOTIFY_WARNING = "euro_cds_broker_notify_warning";

	
	/**
	 * 
	* @author： Dustyone
	* @Title：messgaeConfirmChannel 
	* @Description：TODO
	* @param ：@return 
	* @return ：MessageChannel 
	* @throws
	 */
	@Output(MESSAGE_CONFIRM_CHANNEL)
	public MessageChannel messgaeConfirmChannel();
	
	/**
	 * 
	* @Title：asiaCdsBrokerWarningNotify 
	* @Description：TODO
	* @param ：@return 
	* @return ：MessageChannel 
	* @throws
	 */
	@Input(ASIA_CDS_BROKER_NOTIFY_WARNING)
	public MessageChannel asiaCdsBrokerWarningNotify();
	
	/**
	 * 
	* @Title：euroCdsBrokerWarningNotify 
	* @Description：TODO
	* @param ：@return 
	* @return ：MessageChannel 
	* @throws
	 */
	@Input(EURO_CDS_BROKER_NOTIFY_WARNING)
	public MessageChannel euroCdsBrokerWarningNotify();
	
}
